package com.cc.wechat.mq.constant;

/**
 * RabbitMQ常量类
 */
public class RabbitMQConstants {
    // 交换机
    public static final String CHAT_EXCHANGE = "chat.exchange";// 聊天交换机
    public static final String NOTIFICATION_EXCHANGE = "notification.exchange";// 通知交换机

    // 队列
    public static final String PRIVATE_MESSAGE_QUEUE = "private_message_queue";// 私聊消息队列
    public static final String GROUP_MESSAGE_QUEUE = "group_message_queue";// 群聊消息队列
    public static final String FRIEND_REQUEST_QUEUE = "friend_request_queue";// 好友请求队列
    public static final String FRIEND_RESPONSE_QUEUE = "friend_response_queue";// 好友响应队列
    public static final String MESSAGE_READ_QUEUE = "message_read_queue";// 消息已读队列
    public static final String MESSAGE_RECALL_QUEUE = "message_recall_queue";// 消息撤回队列

    // 路由键
    public static final String PRIVATE_MESSAGE_ROUTING_KEY = "chat.message.private";// 私聊消息路由键
    public static final String GROUP_MESSAGE_ROUTING_KEY = "chat.message.group";// 群聊消息路由键
    public static final String FRIEND_REQUEST_ROUTING_KEY = "notification.friend.request";// 好友请求路由键
    public static final String FRIEND_RESPONSE_ROUTING_KEY = "notification.friend.response";// 好友响应路由键

    // 死信相关
    public static final String DEAD_LETTER_EXCHANGE = "chat.dlx";// 死信交换机
    public static final String DEAD_LETTER_QUEUE = "chat.dlq";// 死信队列
    public static final String DEAD_LETTER_ROUTING_KEY = "chat.dlx.key";// 死信路由键
} 